package com.we.flink.dcapiuserlabel.table;

import java.sql.Timestamp;

public class TableDcSubmitRecord {
    public static final String KFKTABLE = "fdm.hhl01_dc_submit_record";
    public static final String QUERYSQL =
            "select uid, create_time from "
                    + KFKTABLE
                    + " where submit_step = 3 and create_time is not null";

    public long uid;
    public Timestamp create_time;

    public TableDcSubmitRecord() {}

    public long getUid() {
        return uid;
    }

    public Timestamp getCreate_time() {
        return create_time;
    }
}
